package cn.boat.router.broker.partition;

import cn.boat.router.broker.Message;
import cn.boat.router.exception.BoatMQException;

import java.util.List;

public interface PartitionSelector {

    /**
     * 获取分区
     * @param topic
     * @param partitions
     * @param message
     * @return
     * @throws BoatMQException
     */
    public Partition getPartition(String topic, List<Partition> partitions, Message message) throws BoatMQException, BoatMQException;
}
